package com.zhxy.util.message;

/**
 * 识别一个消息是request还是response
 * @author 刘勉
 *
 */
public interface RequestResponseProcessor extends AsyncMessageProcessor<MessagePipe, Object> {
	
	/**
	 * 该消息是否是request
	 * @param pipe 管道
	 * @param message 消息
	 * @return
	 */
	boolean isRequest(MessagePipe pipe, Object message);
	
	/**
	 * 该消息是否是response
	 * @param pipe 管道
	 * @param message 消息
	 * @return
	 */
	boolean isResponse(MessagePipe pipe, Object message);
	
}
